package com.bee.shepherd.rpc.qmq.consumer;

import org.springframework.stereotype.Service;
import qunar.tc.qmq.Message;
import qunar.tc.qmq.consumer.annotation.QmqConsumer;

/**
* Created by xiaolong.zhao on 19/1/24.
*/
@Service
public class DemoConsumer {

//    @QmqConsumer(prefix = "${qmq.demo.topic}", consumerGroup = "${qmq.receive.group}")
    public void demoConsumer(Message message) throws Exception {
        //todo 业务代码
    }
}
